package com.example.redisson.redisson.message;

import jakarta.annotation.Resource;
import org.redisson.api.RTopic;
import org.redisson.api.RedissonClient;
import org.springframework.stereotype.Component;

@Component
public class MessagePublisher {

    @Resource
    private RedissonClient redissonClient;

    // 发布消息，有调用者自行发布消息
    public void publish(String message) {
        // 获取一个发布/订阅对象，如果不存在则创建
        RTopic topic = redissonClient.getTopic("myTopic");

        // 准备数据，这里假设是字符串
        // String message = "Hello, world!";

        // 发布一条消息
        topic.publish(message);
    }

}
